package com.celeritymq.server.servers;

import java.io.Serializable;
import java.rmi.Remote;
import java.rmi.RemoteException;

import com.celeritymq.producer.CelerityQueueSender;
import com.celeritymq.producer.CelerityTopicPublisher;

public interface ProducerAcceptor extends Remote,Serializable{
	//将topic发送者加入管理名单
	void addToTopicPublisherMap(CelerityTopicPublisher topicPublisher)throws RemoteException;
	//将queue发送者加入管理名单
	void addToQueueSenderMap(CelerityQueueSender queueSender)throws RemoteException;
	//设定该Acceptor要将消息传送到的topic Manager
	void setTopicManager(TopicManager topicManager);
	//设定该Acceptor要将消息传送到的queue Manager
	void setQueueManager(QueueManager queueManager);
}